package com.doitedu.day03.funcs

import java.sql.DriverManager
import scala.io.Source

/**
 * @Date 22.6.22
 * @Created by HANGGE
 * @Description
 */
object _03LoadData2Mysql {
  def main(args: Array[String]): Unit = {
    // 读取文件数据
    // 1 加载文件
    val bufferedSource = Source.fromFile("E://stu.txt")
    // 2  获取文件中的每行数据
    val lines = bufferedSource.getLines()


    // 3 将数据写入到MySQL
    // 获取MySQL的连接对象
    val conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/doit32", "root", "root")
    // 获取执行sql的对象
    val ps = conn.prepareStatement("insert  into  tb_stu values (?,?,?,?)")
    // 遍历每行数据
    lines.foreach(line => {
      // 处理每行数据
      val arr = line.split(",")
      //  将每行数据的属性设置到指定的位置
      ps.setInt(1, arr(0).toInt)
      ps.setString(2, arr(1))
      ps.setInt(3, arr(2).toInt)
      ps.setString(4, arr(3))
      // 执行SQL
      ps.executeUpdate()
    })
    // 释放资源
    ps.close()
    conn.close()

  }

}
